e4e09606f1bf4ad1eeee5b98133fa415c5ddc92a,src/org/jgroups/protocols/ENCRYPT.java,ENCRYPT,sendDown,#Event#,1009
Before Change
if (msg.getBuffer() != null) {
// copy neeeded because same message (object) may be retransmitted -> no double encryption
Message msgEncrypted = msg.copy(false);
msgEncrypted.setBuffer(encryptMessage(symEncodingCipher, msg.getBuffer()));
passDown(new Event(Event.MSG, msgEncrypted));
return;
}
After Change
}
Message msg = (Message) evt.getArg();
if(msg.getLength() == 0) {
passDown(evt);
return;
}
EncryptHeader hdr=new EncryptHeader(EncryptHeader.ENCRYPT, getSymVersion());
hdr.encrypt_entire_msg=this.encrypt_entire_message;
if(encrypt_entire_message) {
byte[] serialized_msg=Util.streamableToByteBuffer(msg);
byte[] encrypted_msg=encryptMessage(symEncodingCipher, serialized_msg);
Message tmp=msg.copy(false); // we need to preserve headers which may already be present
tmp.setBuffer(encrypted_msg);
tmp.setSrc(local_addr);
tmp.putHeader(EncryptHeader.KEY, hdr);
passDown(new Event(Event.MSG, tmp));
return;
}
// put our encrypt header on the message
msg.putHeader(EncryptHeader.KEY, hdr);
// copy neeeded because same message (object) may be retransmitted -> no double encryption
Message msgEncrypted = msg.copy(false);
msgEncrypted.setBuffer(encryptMessage(symEncodingCipher, msg.getBuffer()));
passDown(new Event(Event.MSG, msgEncrypted));
}